/**
 * %%
 * %%
 */
package org.apache.flink.runtime.allocation;

import org.apache.flink.api.common.ConsumerID;
import org.apache.flink.api.common.ResourceStatus;

/**
 * @类名: ResourceAllocation
 * @说明: 资源分配，资源管理器视图
 *         1 资源的worker视图
		   2 资源的消费者视图，资源分配给哪个消费者，支持session模式多消费者
		   3 消费者获分配资源量状态，统计
		   4 分片视图，资源slot分配给哪个分片，用户实现

 *
 * @author   leehom
 * @Date	 2024年1月23日 下午5:44:54
 * 修改记录：
 *
 * @see 	 
 */
public class ResourceAllocation {
	
	/** 所属消费者*/
	private final ConsumerID consumerId;
	
	public ResourceAllocation(ConsumerID consumerId) {
		super();
		this.consumerId = consumerId;
	}

	// 资源分配统计
	public ResourceAllocationStatistics stat() {
		return null;
	}
	
	// 资源状态
	public ResourceStatus status() {
		return ResourceStatus.LOW;
	}

	public ConsumerID getConsumerId() {
		return consumerId;
	}
	
	
}
